<?php
include_once "ConexionBD.php";
include_once "../negocio/Cliente.php";

class EmpresaSQL{

    private $sql;


    function EmpresaSQL() {$this->sql = ConexionBD::getInstancia();}

    public function ingresarDatos(&$obj){
     
        $conn = $this->sql->getConexion();
	$sql="select rut from EMPRESA where rut ='".$obj->getRut()."'";
        $resultado = array();
        $resultado = $this->sql->ejecutarSql($sql);
        if (isset($resultado[0][0]) && $resultado[0][0]==$obj->getRut()){
            //die("Error de conexion. ". pg_last_error());
            return 0;
        }

        $sql="insert into Empresa values('".$obj->getNombre()."', '".$obj->getRut()."', '".$obj->getCredito()."', '".$obj->getRut_notaria()."' )";

        if (!pg_query( $conn , $sql )){
            //die("Error de conexion. ". pg_last_error());
            return 0;
        }
        else return 1;
        pg_close($conn);
    }

    public function modificarDatos(&$obj){

        $sql=   "UPDATE EMPRESA
                SET nombre='".$obj->getNombre()."', credito='".$obj->getCredito()."'
                WHERE rut='".$obj->getRut()."'";

        $conn = $this->sql->getConexion();
        if (!pg_query( $conn , $sql )){
            die("Error de conexion. ". pg_last_error());
        }
        pg_close($conn);
    }

    public function buscarDatos(&$obj){

        $sql=   "SELECT *
                FROM EMPRESA WHERE
                UPPER(nombre) like UPPER('%".$obj->getNombre()."%')
                AND UPPER(rut) like UPPER('%".$obj->getRut()."%')
                ORDER BY rut ASC";
        //echo "<br>$sql<br>";
        $resultado = $this->sql->ejecutarSql($sql);
        return $resultado;
    }

}

?>